Method: Redborder::KafkaNotifier::MessageQueue#<<

Defined in:
lib/kafka_notifier/message_queue.rb

#<<(x) ⇒ Object 



27
28
29
30
31
32
 
# File 'lib/kafka_notifier/message_queue.rb', line 27

def <<(x)
  @mutex.synchronize do
    @queue << x
    @recieved.signal if @queue.size >= @limit
  end
end